var mysql = require("mysql");
var dbConfig = require('../../config/DBConfig');

var pool = mysql.createPool(dbConfig.mysql);

var query = function(sql, params, callback) {
    pool.getConnection(function(err, conn) {
        if (err) {
            callback(err, null, null);
        } else {
            conn.query(sql, params, function(qerr, rows, fields) {
                //释放连接
                conn.release();
                //事件驱动回调
                callback(qerr, rows, fields);
            });
        }
    });
};

// let query = function(sql, values) {
//     // 返回一个 Promise
//     return new Promise((resolve, reject) => {
//         pool.getConnection(function(err, connection) {
//             if (err) {
//                 reject(err)
//             } else {
//                 connection.query(sql, values, (err, rows) => {

//                     if (err) {
//                         reject(err)
//                     } else {
//                         resolve(rows)
//                     }
//                     // 结束会话
//                     connection.release()
//                 })
//             }
//         })
//     })
// }
module.exports = query;